package com.fmync.ai.fmync.service;

import dev.langchain4j.data.message.ChatMessage;
import dev.langchain4j.service.TokenStream;
import reactor.core.publisher.Flux;

public interface StreamingAssistant {

        TokenStream chat(ChatMessage message);


        Flux<String> chatStream(ChatMessage message);
}